Node / ReticulumProjects / MeshChatX.git / files / meshchatx / src / backend / http / ws / dispatch.py

Displaying Raw • Download

T8b949e# SPDX-License-Identifier: 0BSD

T8b949e"""WebSocket inbound dispatch extracted from ReticulumMeshChat."""

Tff7b72from T7ee787__future__ Tff7b72import Te6edf3annotations

Tff7b72from T7ee787meshchatxT7ee787.T7ee787srcT7ee787.T7ee787backendT7ee787.T7ee787httpT7ee787.T7ee787live_names Tff7b72import Te6edf3inject_meshchat_names

Tff7b72from T7ee787meshchatxT7ee787.T7ee787srcT7ee787.T7ee787backendT7ee787.T7ee787demo_mode Tff7b72import Te6edf3demo_mode_blocks_ws_type

Tff7b72from T7ee787meshchatxT7ee787.T7ee787srcT7ee787.T7ee787backendT7ee787.T7ee787httpT7ee787.T7ee787meshchat_names Tff7b72import Tb4b4b4( T8b949e# noqa: F401

Te6edf3AsyncUtilsTb4b4b4,

Te6edf3jsonTb4b4b4,

Te6edf3loggerTb4b4b4,

Te6edf3websocket_type_requires_authTb4b4b4,

Tb4b4b4)

Tff7b72from T7ee787meshchatxT7ee787.T7ee787srcT7ee787.T7ee787backendT7ee787.T7ee787httpT7ee787.T7ee787wsT7ee787.T7ee787handlers_core Tff7b72import Te6edf3HANDLERS Tff7b72as Te6edf3_CORE_HANDLERS

Tff7b72from T7ee787meshchatxT7ee787.T7ee787srcT7ee787.T7ee787backendT7ee787.T7ee787httpT7ee787.T7ee787wsT7ee787.T7ee787handlers_lxmf Tff7b72import Te6edf3HANDLERS Tff7b72as Te6edf3_LXMF_HANDLERS

Tff7b72from T7ee787meshchatxT7ee787.T7ee787srcT7ee787.T7ee787backendT7ee787.T7ee787httpT7ee787.T7ee787wsT7ee787.T7ee787handlers_nomad Tff7b72import Te6edf3HANDLERS Tff7b72as Te6edf3_NOMAD_HANDLERS

Tff7b72from T7ee787meshchatxT7ee787.T7ee787srcT7ee787.T7ee787backendT7ee787.T7ee787httpT7ee787.T7ee787wsT7ee787.T7ee787handlers_rns_link Tff7b72import Tb4b4b4(

Te6edf3HANDLERS Tff7b72as Te6edf3_RNS_LINK_HANDLERSTb4b4b4,

Tb4b4b4)

Te6edf3_NS_READY Tff7b72= Tff7b72False

Te6edf3WS_HANDLERS Tff7b72= Tb4b4b4{Tb4b4b4}

Te6edf3WS_HANDLERSTff7b72.Td2a8ffupdateTb4b4b4(Te6edf3_CORE_HANDLERSTb4b4b4)

Te6edf3WS_HANDLERSTff7b72.Td2a8ffupdateTb4b4b4(Te6edf3_NOMAD_HANDLERSTb4b4b4)

Te6edf3WS_HANDLERSTff7b72.Td2a8ffupdateTb4b4b4(Te6edf3_LXMF_HANDLERSTb4b4b4)

Te6edf3WS_HANDLERSTff7b72.Td2a8ffupdateTb4b4b4(Te6edf3_RNS_LINK_HANDLERSTb4b4b4)

Te6edf3_HANDLER_MODULES Tff7b72= Tb4b4b4(

Ta5d6ff"Ta5d6ffmeshchatx.src.backend.http.ws.handlers_coreTa5d6ff"Tb4b4b4,

Ta5d6ff"Ta5d6ffmeshchatx.src.backend.http.ws.handlers_nomadTa5d6ff"Tb4b4b4,

Ta5d6ff"Ta5d6ffmeshchatx.src.backend.http.ws.handlers_lxmfTa5d6ff"Tb4b4b4,

Ta5d6ff"Ta5d6ffmeshchatx.src.backend.http.ws.handlers_rns_linkTa5d6ff"Tb4b4b4,

Tb4b4b4)

Tff7b72def Td2a8ff_ensure_meshchat_namespaceTb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72global Te6edf3_NS_READY

Tff7b72if Te6edf3_NS_READYTb4b4b4:

Tff7b72return

Te6edf3inject_meshchat_namesTb4b4b4(Tffa657globalsTb4b4b4(Tb4b4b4)Tb4b4b4)

Tff7b72for Te6edf3mod_name Tff7b72in Te6edf3_HANDLER_MODULESTb4b4b4:

Te6edf3mod Tff7b72= Tffa657__import__Tb4b4b4(Te6edf3mod_nameTb4b4b4, Te6edf3fromlistTff7b72=Tb4b4b4[Ta5d6ff"Ta5d6ff*Ta5d6ff"Tb4b4b4]Tb4b4b4)

Te6edf3inject_meshchat_namesTb4b4b4(Te6edf3modTff7b72.Td2a8ff__dict__Tb4b4b4)

Te6edf3_NS_READY Tff7b72= Tff7b72True

Tff7b72async Tff7b72def Td2a8ffdispatch_websocket_dataTb4b4b4(Te6edf3appTb4b4b4, Te6edf3clientTb4b4b4, Te6edf3dataTb4b4b4)Tb4b4b4:

Te6edf3_ensure_meshchat_namespaceTb4b4b4(Tb4b4b4)

T8b949e# get type from client data

Tff7b72if Tff7b72not Tffa657isinstanceTb4b4b4(Te6edf3dataTb4b4b4, Tffa657dictTb4b4b4)Tb4b4b4:

Tff7b72return

Te6edf3_type Tff7b72= Te6edf3dataTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fftypeTa5d6ff"Tb4b4b4)

Tff7b72if Tff7b72not Te6edf3_typeTb4b4b4:

Tff7b72return

Tff7b72if Te6edf3demo_mode_blocks_ws_typeTb4b4b4(Te6edf3appTb4b4b4, Te6edf3_typeTb4b4b4)Tb4b4b4:

Te6edf3loggerTff7b72.Td2a8ffwarningTb4b4b4(Ta5d6ff"Ta5d6ffRejected WebSocket mutator in demo mode: Tffd700%sTa5d6ff"Tb4b4b4, Te6edf3_typeTb4b4b4)

Te6edf3AsyncUtilsTff7b72.Td2a8ffrun_asyncTb4b4b4(

Te6edf3clientTff7b72.Td2a8ffsend_strTb4b4b4(

Te6edf3jsonTff7b72.Td2a8ffdumpsTb4b4b4(

Tb4b4b4{

Ta5d6ff"Ta5d6fftypeTa5d6ff"Tb4b4b4: Ta5d6ff"Ta5d6fferrorTa5d6ff"Tb4b4b4,

Ta5d6ff"Ta5d6ffmessageTa5d6ff"Tb4b4b4: Ta5d6ff"Ta5d6ffDemo mode is read-onlyTa5d6ff"Tb4b4b4,

Ta5d6ff"Ta5d6ffcodeTa5d6ff"Tb4b4b4: Ta5d6ff"Ta5d6ffdemo_readonlyTa5d6ff"Tb4b4b4,

Tb4b4b4}Tb4b4b4,

Tb4b4b4)Tb4b4b4,

Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tff7b72return

Tff7b72if Te6edf3websocket_type_requires_authTb4b4b4(Te6edf3_typeTb4b4b4)Tb4b4b4:

Tff7b72if Tff7b72not Tff7b72await Te6edf3appTff7b72.Td2a8ff_websocket_session_authorizedTb4b4b4(Te6edf3clientTb4b4b4)Tb4b4b4:

Te6edf3loggerTff7b72.Td2a8ffwarningTb4b4b4(Ta5d6ff"Ta5d6ffRejected unauthorized WebSocket mutator: Tffd700%sTa5d6ff"Tb4b4b4, Te6edf3_typeTb4b4b4)

Te6edf3AsyncUtilsTff7b72.Td2a8ffrun_asyncTb4b4b4(

Te6edf3clientTff7b72.Td2a8ffsend_strTb4b4b4(

Te6edf3jsonTff7b72.Td2a8ffdumpsTb4b4b4(

Tb4b4b4{

Ta5d6ff"Ta5d6fftypeTa5d6ff"Tb4b4b4: Ta5d6ff"Ta5d6fferrorTa5d6ff"Tb4b4b4,

Ta5d6ff"Ta5d6ffmessageTa5d6ff"Tb4b4b4: Ta5d6ff"Ta5d6ffAuthentication requiredTa5d6ff"Tb4b4b4,

Tb4b4b4}Tb4b4b4,

Tb4b4b4)Tb4b4b4,

Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tff7b72return

Te6edf3handler Tff7b72= Te6edf3WS_HANDLERSTff7b72.Td2a8ffgetTb4b4b4(Te6edf3_typeTb4b4b4)

Tff7b72if Te6edf3handler Tff7b72is Tff7b72NoneTb4b4b4:

Tffa657printTb4b4b4(Ta5d6ff"Ta5d6ffunhandled client message type: Ta5d6ff" Tff7b72+ Te6edf3_typeTb4b4b4)

Tff7b72return

Tff7b72await Te6edf3handlerTb4b4b4(Te6edf3appTb4b4b4, Te6edf3clientTb4b4b4, Te6edf3dataTb4b4b4)